<template>
	<view>
		<!--触顶时，拉取历史消息-->
		<view class="tips color_fff size_12 align_c" :class="{ 'show':ajax.loading }" @tap="getHistoryMsg">{{ajax.loadText}}</view>
		
		<!--存放消息的区域-->
		<view class="box-1" id="list-box">
			<view class="talk-list" v-if="flag">
				<!--历史记录里的每天消息-->
				<view v-for="(item,index) in talkList" :key="index" :id="`msg-${item.id}`">
					<!--push样式是当前用户发的消息，pull样式是当前用户接收的消息-->
					<view class="item flex_col" :class=" item.type == 1 ? 'push':'pull' ">
						<image :src="item.type == 1 ? loginUser.avatar:anotherUser.avatar" mode="aspectFill" class="pic"></image><!--消息发送者的头像-->
						<view class="content">{{item.content}}</view><!--消息的内容-->
					</view>
				</view>
			</view>
		</view>
		
		<!--文本输入框与发送按钮区域-->
		<view class="box-2">
			<view class="flex_col">
				<!--文本输入框-->
				<view class="flex_grow">
					<input type="text" class="content" v-model="content" placeholder="请输入聊天内容" placeholder-style="color:#DDD;" :cursor-spacing="6">
				</view>
				<button class="send" @tap="send">发送</button>
			</view>
		</view>
	</view>
</template>

<script>
	import c from "@/utils/Constant.js"
	import messageApi from '@/request/api/messageApi.js'
	import userUtils from '@/utils/userUtils.js'
	import userApi from '@/request/api/userApi.js'
	import chatSocket from '@/request/websocket/chatWebsocket.js'
	export default {
		data() {
			return {
				talkList:[], //存储历史消息的数组
				messages:[],
				earliestMessageTime:null,
				loginUser:{
					id:'',
					nickname:'',
					avatar:''
				},
				anotherUser:{
					id:'',
					nickname:'',
					avatar:''
				},
				ajax:{
					rows:11,	//每页数量
					page:1,	//页码
					flag:true,	// 请求开关
					loading:true,	// 加载中
					loadText:'正在获取消息'
				},
				flag:true,
				content:'',
				socket:null
			}
		},
		mounted() { //组件创建时，拉取两位用户的基础信息,拉取历史消息
			this.$nextTick(()=>{
				userApi.userBaseInfo(this.loginUser.id).then((data)=>{
					if(data.code == 0){
						this.loginUser = data.user
					}
				})
				userApi.userBaseInfo(this.anotherUser.id).then((data)=>{
					if(data.code == 0){
						this.anotherUser = data.user
					}
				})
				this.getHistoryMsg();
			});
			
		},
		onLoad (options) {
			//根据其他页面传来的用户id，拉取聊天历史记录
			this.anotherUser.id = options.id
			this.loginUser.id = userUtils.getLoginUserId();
			chatSocket.init(options.id)
			let socket = chatSocket.open()
			//连接发生错误的回调方法
			socket.onerror = this.socketError;
			//连接成功建立的回调方法
			socket.onopen = this.socketOpen
			//接收到消息的回调方法
			socket.onmessage = this.receive
			//连接关闭的回调方法
			socket.onclose = this.socketClose
			this.socket = socket
		},
		onPageScroll(e){ //触顶拉取历史记录
			if(e.scrollTop<5){
				this.getHistoryMsg();
			}
		},
		//用户返回页面时，关闭socket
		onBackPress() {
			if(this.socket){
				this.socket.close();
			}
		},
		methods: {
			// 获取历史消息
			getHistoryMsg(){
				if(!this.ajax.flag){
					return; //
				}
				
				let queryParams = {
					currentPage:this.ajax.page, //当前页
					size:this.ajax.rows,//每页记录数
					messageType:c.action.PRIVATE_CHAT //只查询私聊类型的消息
				}
				messageApi.historyList(this.anotherUser.id,queryParams).then((data)=>{
					this.hideLoadTips();
					var arr = [];
					if(data.code == 0){
						let messages = data.page.list;
						messages.forEach((message)=>{
							let formatMsg = this.formatMessage(message)
							this.messages.push(formatMsg)
						})
						/*
							颠倒数组中元素的顺序。将最新的数据排在本次接口返回数据的最后面。
							后端接口按 消息的时间降序查找出当前页的数据后，再将本页数据按消息时间降序排序返回。
							这是数据的重点，因为页面滚动条和上拉加载历史的问题。
						 */
						this.messages.reverse();
						this.hideLoadTips(true);
					}else{
						this.messages = [];
					}
					this.ajax.flag = false;  //关闭拉取消息，等数据请求回来才允许拉取

					// 获取待滚动元素选择器，解决插入数据后，滚动条定位时使用
					let selector = '';
					//console.log(data)					
					if(this.ajax.page>1){
						// 非第一页，则取历史消息数据的第一条信息元素
						selector = `#msg-${this.talkList[0].id}`;
					}else{
						// 第一页，则取当前消息数据的最后一条信息元素
						selector = `#msg-${this.messages[this.messages.length-1].id}`;
					}
					
					// 将获取到的消息数据合并到消息数组中
					this.talkList = [...this.messages,...this.talkList];	
					this.earliestMessageTime = this.talkList[this.talkList -1]
					// 数据挂载后执行，不懂的请自行阅读 Vue.js 文档对 Vue.nextTick 函数说明。
					this.$nextTick(()=>{
						// 设置当前滚动的位置
						this.setPageScrollTo(selector);
						console.log(this.messages.length)						
						if(this.messages.length < this.ajax.rows){
							// 当前消息数据条数小于请求要求条数时，则无更多消息，不再允许请求。
							// 可在此处编写无更多消息数据时的逻辑
							
						}else{//（请求数据成功后，页数自增，开放允许拉取消息）
							this.ajax.page ++;
							
							// 延迟 200ms ，以保证设置窗口滚动已完成
							setTimeout(()=>{
								this.ajax.flag = true;
							},200)
						}
						this.messages = [];
						
					})	
				}).catch((err)=>{
					console.log(err)
				})
			},
			// 拼接历史记录消息，正式项目可替换为请求历史记录接口
			joinHistoryMsg(){  //=====================重点关注该方法，再这里拉取历史记录==============================
				 
			},
			formatMessage(message){
				let loginUserId = userUtils.getLoginUserId();
				let formatMsg = {
					"id":message.id,	// 消息的ID
					"content":message.content,	// 消息内容
					"createTime":message.createTime
				}
				if(loginUserId == message.senderId){
					formatMsg["type"] = 1;
				}else{
					formatMsg["type"] = 0;
				}
				return formatMsg
			},
			// 设置页面滚动位置
			setPageScrollTo(selector){
				let view = uni.createSelectorQuery().in(this).select(selector);
				view.boundingClientRect((res) => {
					uni.pageScrollTo({
					    scrollTop:res.top - 30,	// -30 为多显示出大半个消息的高度，示意上面还有信息。
					    duration: 0
					});
				}).exec();
			},
			// 隐藏加载提示
			hideLoadTips(flag){
				if(flag){
					this.ajax.loadText = '消息获取成功';
					setTimeout(()=>{
						this.ajax.loading = false;
					},300);
				}else{
					this.ajax.loading = true;
					this.ajax.loadText = '正在获取消息';
				}
			},
			// 发送信息
			send(){   //=====================重点关注该方法==============================
				if(!this.content){
					uni.showToast({
						title:'请输入有效的内容',
						icon:'none'
					})
					return;
				}
				
				uni.showLoading({
					title:'正在发送'
				})
				uni.hideLoading();
				chatSocket.send(this.content);
				// 清空内容框中的内容
				this.content = '';
			},
			socketError(event){
				
			},
			socketOpen(event){
				
			},
			receive(event){
				let result =JSON.parse(event.data);
				if(result.content){
					let message = this.formatMessage(result)
					this.talkList.push(message);
					this.$nextTick(()=>{
						uni.pageScrollTo({
						    scrollTop: 999999,	// 设置一个超大值，以保证滚动条滚动到底部
						    duration: 0
						});
					})
				}
			},
			socketClose(event){
				
			}
			
		}
	}
</script>

<style lang="scss">
	@import "../../lib/global.scss";
	page{
		background-color: #F3F3F3;
		font-size: 28rpx;
	}
	
	/* 加载数据提示 */
	.tips{
		position: fixed;
		left: 0;
		top:var(--window-top);
		width: 100%;
		z-index: 9;
		background-color: rgba(0,0,0,0.15);
		height: 72rpx;
		line-height: 72rpx;
		transform:translateY(-80rpx);
		transition: transform 0.3s ease-in-out 0s;
		
		&.show{
			transform:translateY(0);
		}
	}
	
	.box-1{
		width: 100%;
		height: auto;
		padding-bottom: 100rpx;
		box-sizing: content-box;
		
		/* 兼容iPhoneX */
		margin-bottom: 0;  
		margin-bottom: constant(safe-area-inset-bottom);  
		margin-bottom: env(safe-area-inset-bottom);  
	}
	.box-2{
		position: fixed;
		left: 0;
		width: 100%;
		bottom: 0;
		height: auto;
		z-index: 2;
		border-top: #e5e5e5 solid 1px;
		box-sizing: content-box;
		background-color: #F3F3F3;
		
		/* 兼容iPhoneX */
		padding-bottom: 0;  
		padding-bottom: constant(safe-area-inset-bottom);  
		padding-bottom: env(safe-area-inset-bottom);  
		
		>view{
			padding: 0 20rpx;
			height: 100rpx;
		}
		
		.content{
			background-color: #fff;
			height: 64rpx;
			padding: 0 20rpx;
			border-radius: 32rpx;
			font-size: 28rpx;
		}
		
		.send{
			background-color: #42b983;
			color: #fff;
			height: 64rpx;
			margin-left: 20rpx;
			border-radius: 32rpx;
			padding: 0;
			width: 120rpx;
			line-height: 62rpx;
			
			&:active{
				background-color: #5fc496;
			}
		}
	}
	
	.talk-list{
		padding-bottom: 20rpx;
		
		/* 消息项，基础类 */
		.item{
			padding: 20rpx 20rpx 0 20rpx;
			align-items:flex-start;
			align-content:flex-start;
			color: #333;
			
			.pic{
				width: 92rpx;
				height: 92rpx;
				border-radius: 50%;
				border: #fff solid 1px;
			}
			
			.content{
				padding: 20rpx;
				border-radius: 4px;
				max-width: 500rpx;
				word-break: break-all;
				line-height: 52rpx;
				position: relative;
			}
			
			/* 收到的消息 */
			&.pull{
				.content{
					margin-left: 32rpx;
					background-color: #fff;
					
					&::after{
						content: '';
						display: block;
						width: 0;
						height: 0;
						border-top: 16rpx solid transparent;
						border-bottom: 16rpx solid transparent;
						border-right: 20rpx solid #fff;
						position: absolute;
						top: 30rpx;
						left: -18rpx;
					}
				}
			}
			
			/* 发出的消息 */
			&.push{
				/* 主轴为水平方向，起点在右端。使不修改DOM结构，也能改变元素排列顺序 */
				flex-direction: row-reverse;
				
				.content{
					margin-right: 32rpx;
					background-color: #a0e959;
					
					&::after{
						content: '';
						display: block;
						width: 0;
						height: 0;
						border-top: 16rpx solid transparent;
						border-bottom: 16rpx solid transparent;
						border-left: 20rpx solid #a0e959;
						position: absolute;
						top: 30rpx;
						right: -18rpx;
					}
				}
			}
		}
	}
</style>